package com.itcast.mongodb;
import com.mongodb.client.MongoClient;
import com.mongodb.client.MongoClients;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.MongoCollection;
import org.bson.Document;

public class MongoDBConnection{
    public static void main(String[] args) {
        // 设置MongoDB连接字符串，格式一般为 "mongodb://host:port"
        String connectionString = "mongodb://localhost:27017";
        // 创建MongoClient实例
        MongoClient mongoClient = MongoClients.create(connectionString);

        try {
            // 连接到指定的数据库，如果数据库不存在则会自动创建 数据库名
            MongoDatabase database = mongoClient.getDatabase("yiyi");
            // 获取集合
            MongoCollection<Document> collection = database.getCollection("apple");

            // 此处可以添加数据库操作代码，例如插入、查询等
            System.out.println("Connected to database successfully");
            // 准备文档数据
            Document document = new Document("name", "yiyi")
                    .append("email", "2904706188@qq.com")
                    .append("age", 22);

            // 插入文档
            collection.insertOne(document);
            // 输出插入成功的提示
            System.out.println("Document inserted successfully");

//            // 示例：查询集合中的所有文档
//            // 使用find()方法获取集合中的所有文档
//            collection.find().forEach(document -> {
//                // 输出每个文档的内容
//                System.out.println(document.toJson());
//            });


//            //           删除数据库
//            database.drop();
//            System.out.println("Database dropped successfully");
////            删除集合
//            collection.drop();
//            System.out.println("Collection dropped successfully");

        } finally {
            mongoClient.close();
        }
    }
}
